package net.xdevelop.timeserver;

import java.net.Socket;
import java.io.*;
/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

public class Client {
    public Client() {
    }

    public static void main(String[] args) {
        for (int i=0;i<40;i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    for (int j=0;j<60;j++){
                        new Thread(new TestThread()).start();
                    }
                }
            }).start();
        }

    }
    static class TestThread implements Runnable{

        @Override
        public void run() {
            Socket client = null;
            DataOutputStream out = null;
            DataInputStream in = null;
            try {
                client = new Socket("star", 5100);
                client.setSoTimeout(10000);
                out = new DataOutputStream( (client.getOutputStream()));

                String query = "GB";
                byte[] request = query.getBytes();
                out.write(request);
                out.flush();
                client.shutdownOutput();

                in = new DataInputStream(client.getInputStream());
                byte[] reply = new byte[40];
                in.read(reply);
                System.out.println("Time: " + new String(reply, "GBK"));

                in.close();
                out.close();
                client.close();
            }
            catch (Exception e) {
                System.out.println(e.getMessage());
            }
        }
    }

}
